package com.tmt.metrics;

import org.springframework.stereotype.Service;

import com.google.common.eventbus.Subscribe;
import com.swak.eventbus.Event;

/**
 * 指标处理器: 收集到的指标是json格式的
 * 
 * @author lifeng
 * @date 2020年11月19日 下午5:13:10
 */
@Service
public class MetricsHandler {

	/**
	 * 处理指标
	 * 
	 * @param event
	 */
	@Subscribe
	public void metricsHandler(Event event) {
		if (event != null && event.getKey().equals("metrics_channel")) {
			String $metrics = event.getMessage();
			System.out.println($metrics);
		}
	}
}